package com.cellulam.framework.mq.listener;

import com.cellulam.framework.mq.RocketMqConsumerConfig;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class MqConsumeInfo {

    /**
     * GROUP ID，一个实例的group不能重复，分布式同一group下消费者订阅必须完全一样
     * @return
     */
    private String groupId;

    private MqListener subscriber;

    private RocketMqConsumerConfig consumerConfig;
}
